package com.merak.miner.data.kafka.config;

public class KafkaConstant {

    //自定义topic
    public static final String TOPIC_TEST= "topic.test";

    //自定义topic的消费组
    public static final String TOPIC_GROUP1 = "topic.group1";


}
